package com.young.springboot.kafka;

/**
 * @description：
 * @author: yangyahui01
 * @date: 12/5/24 2:55 PM
 */
@FunctionalInterface
public interface RecordFilter<V> {

    /**
     * 返回true，表示消息被过滤而不传递给listener
     * @param record
     * @return
     */
    boolean filter(V record);
}
